package com.share.bigdata.phoenix._main;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.share.common.utils.DbUtil;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

//hive与phoenix应用冲突不能放在一起,放在一起无法启动,需要分开
public class MainPhoenix {
    static String JDBC_PHOENIX = "jdbc:phoenix:node63.snyq.ltd:2181/hbase";

    public static void main(String[] args) {
        try {
            // 加载Phoenix JDBC驱动
            Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");

            // 构建Phoenix连接URL
            String url = JDBC_PHOENIX; // 替换为你的Zookeeper Quorum

            // 建立连接
            Connection conn = DriverManager.getConnection(url);

            // 创建Statement
            Statement statement = conn.createStatement();

            // 执行SQL查询
            ResultSet rs = statement.executeQuery("select * from test_hbase limit 10"); // 替换为你的表名

            // 处理结果
            JSONArray convert = DbUtil.convert(rs);

            System.out.println(JSON.toJSON(convert)); // 替换为你的列名

            // 关闭资源
            rs.close();
            statement.close();
            conn.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
